package com.zls.rabbitmp.work;

import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.zls.rabbitmp.util.ConnectionUtil;

import java.io.IOException;
import java.util.concurrent.TimeoutException;

public class WorkProducer {
    //消息生产者
    public static void main(String[] args) throws IOException, TimeoutException {
        Connection connection = ConnectionUtil.getConnection();//创建链接
        Channel channel = connection.createChannel(); //创建频道
        /**
         * 声明队列
         * 参数1：队列名称
         * 参数2：是否定义持久化队列
         * 参数3：是否独占本次连接
         * 参数4：是否在不使用的时候自动删除队列
         * 参数5：队列其它参数
         * **/
        channel.queueDeclare("work_queue",true,false,false,null);
        for (int i = 0; i < 20; i++) {
            String message = "hello!welcome to qfedu!"+i;
            channel.basicPublish("","work_queue",null,message.getBytes());
        }

        //关闭资源
        channel.close();
        connection.close();

    }
}
